625cb5e57085ff8168d6719e5e56bc7d977d19b8,MobileBuy/buy/src/main/java/com/shopify/buy/dataprovider/ProductServiceDefault.java,ProductServiceDefault,getCollections,#List#,216
Before Change
}
final String queryString = TextUtils.join(",", collectionIds.toArray());
return retrofitService
.getCollections(appId, queryString)
.retryWhen(networkRetryPolicyProvider.provide())
.doOnNext(new RetrofitSuccessHttpStatusCodeHandler<>())
.compose(new UnwrapRetrofitBodyTransformer<CollectionListings, List<Collection>>())
.onErrorResumeNext(new BuyClientExceptionHandler<List<Collection>>())
.observeOn(callbackScheduler);
}
@Override
After Change
}
final String queryString = TextUtils.join(",", collectionIds.toArray());
final Observable<List<Collection>> apiRequest = retrofitService
.getCollections(appId, queryString)
.retryWhen(networkRetryPolicyProvider.provide())
.doOnNext(new RetrofitSuccessHttpStatusCodeHandler<>())
.compose(new UnwrapRetrofitBodyTransformer<CollectionListings, List<Collection>>())
.onErrorResumeNext(new BuyClientExceptionHandler<List<Collection>>());
return ApiInterceptWrapper.wrap(
apiRequest,
requestInterceptor,
responseInterceptor,
new ApiInterceptWrapper.InterceptorCall<ProductApiInterceptor, List<Collection>>() {
@Override
public Observable<List<Collection>> call(ProductApiInterceptor interceptor, Observable<List<Collection>> originalObservable) {
return interceptor.getCollections(collectionIds, originalObservable);
}
}
).observeOn(callbackScheduler);
}
@Override